package com.guige.convert.consumer;

import com.guige.base.constant.Constant;
import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * 交易流水消费者
 *
 * @author songaw
 * @date 2018/5/11 17:05
 */
@Component
@Slf4j
public class ConvertConsumer {


    @KafkaListener(topics = {Constant.KAFKA_CONVERT})
    public void consumer(String message){
        try {
            System.out.println(message);


        }catch (Exception e){
            e.printStackTrace();
        }


    }
}
